// 数据中心
#ifndef __DATA_CENTER_H__
#define __DATA_CENTER_H__

#include <string>
#include <zmq.hpp>

class DataCenter {
public:
    DataCenter(
        const std::string& topicAddr, const std::string& topicName
    );
    ~DataCenter();
    void startup();

private:
    std::string topicAddr;
    std::string topicName;
    zmq::context_t ctx;
    zmq::socket_t sub;
};


#endif